package com.kevin.elasticjob.job;

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
import com.kevin.elasticjob.event.EventCenter;
import com.kevin.elasticjob.event.OrderCreatedEvent;
import com.kevin.elasticjobboot.Job;
import lombok.extern.slf4j.Slf4j;

/**
 * @author Kevin Liu
 * @date 2020/7/30 下午2:53
 */
@Job(jobName = "mySimpleJob",corn = "*/5 * * * * ?")
@Slf4j
public class MySimpleJob implements SimpleJob {

    private final EventCenter eventBusCenter;

    public MySimpleJob(EventCenter eventBusCenter) {
        this.eventBusCenter = eventBusCenter;
    }

    @Override
    public void execute(ShardingContext shardingContext) {
        // 处理创建订单
        // 发送异步事件

        eventBusCenter.postAsync(new OrderCreatedEvent(1L, 1L));
    }
}
